package com.cqupt.tr.component;

import com.cqupt.tr.Utils.callback.OnMessageCallback;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.eclipse.paho.client.mqttv3.MqttException;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Component;

import java.util.HashMap;
import java.util.Map;

@Component
public class MqttClientUtils {

    @Value("${mqttclient.broker.ip}")
    String broker ;


    @Bean
    public Map<String,MqttClient> mqttClientMap() throws MqttException {
            return new HashMap<String, MqttClient>();
    }
}
